package edu.xhu.model.common.constants.kafka.topic;

import lombok.AllArgsConstructor;
import lombok.Getter;

@Getter
@AllArgsConstructor
public class ChatTopic {
    //topic=k-serviceID:发送消息给IM处理
    public static final String BILL_CHAT_TOPIC = "bili-chat-topic";
    //save_detail:异步持久化聊天详情
    public static final String BILL_CHAT_DETAIL_SAVE = "bili-chat-detail-save";
    //处理IM回调信息
    public static final String BILL_CHAT_IM_PROCESS = "bili-chat-im-process";
    //处理持久化回调信息
    public static final String BILL_CHAT_RDB_PROCESS = "bili-chat-rdb-process";
    //处理已读
    public static final String BILL_CHAT_READED_PROCESS = "bili-chat-readed-process";
    //登录监听
    public static final String BILL_CHAT_LOGIN_TOPIC = "bili-chat-login-topic";
}
